草庐IT

java - 同步的、易变的和线程安全的

全部标签

multithreading - goroutine 或多线程在 golang 中不起作用

我试图在golang中实现多线程。我能够实现goroutines,但它没有按预期工作。下面是我准备的示例程序,functest(sstring,fo*os.File){vars1[105]intcount:=0forx:=1000;x输出-good0bye0bye0bye0bye0good1bye1bye1bye1bye1good2bye2bye2bye2bye2....等等。上面的程序会创建一个文件,并在文件中写入“Hello”和“bye”。我的问题是我正在尝试创建5个线程并希望使用不同的线程处理不同的值。如果你会看到上面的例子,它打印了4次“bye”。我希望使用5个线程输出如下所示

multithreading - Golang线程不是每次都执行

这个问题在这里已经有了答案:Nooutputfromgoroutine(3个答案)Goroutinedoesnotexecuteiftime.Sleepincluded(1个回答)关闭4年前。所以,我正在测试Golang。我知道fmt.Println不是线程安全的。所以,我尝试了sync.Mutex。程序如下:functhreder(mux*Mutex,iint){mux.Lock()fmt.Println("Iamthread:",i)mux.Unlock()return}funcmain(){m:=&Mutex{}fori:=0;i我期待300行输出。但是,我得到80-90行。我哪

go - 使用 goroutine 的多线程

我正在尝试使用Go来自动化我的侦察工具。到目前为止,我可以在kali(Nikto/whois)中运行两个基本工具。现在我希望它们并行执行,而不是等待一个函数完成。阅读了一下之后,我开始知道这可以通过使用goroutines来实现。但我的代码似乎不起作用:packagemainimport("log""os/exec""os""fmt")varurlstringfuncnikto(){cmd:=exec.Command("nikto","-h",url)cmd.Stdout=os.Stdouterr:=cmd.Run()iferr!=nil{log.Fatal(err)}}funcwho

go - 由于 slice 中的项目数正在变化,如何安全地从 slice 中删除项目

在我遍历用户slice后,我需要根据某些条件从slice中删除一些用户。我将多次遍历此用户slice,慢慢删除一些元素。我从其他语言了解到,在循环时从集合中删除项目是不安全的。所以我正在做的是将我想要删除的元素存储在maptoMutate中。原始循环完成后,我会继续尝试从slice中删除元素。toMutate:=make(map[int]User,100)foridx,u:=rangec.users{ifsomeCondition{toMutate[idx]=u}}然后我调用此函数从用户的slice中删除项目。foridx,u:=rangetoMutate{c.users=append

go - 是否可以断言通过像 Java Mockito 一样在 Go 中进行 spy 事件来调用真正的方法?

我正在寻找断言我的测试中涵盖了一个语句。例如,假设从测试开始调用methodA(),它引用了methodB()。我想断言在从测试中执行methodA()时会调用methodB()。在下面的代码中,我如何在Go测试中断言svc.AddCheck()在执行svc.OnStartup()时被调用?func(svc*Servjice)OnStartup()error{iferr:=svc.AddCheck("cache");err!=nil{returnerr}returnnil} 最佳答案 Isitpossibletoassertthat

multithreading - 自同步 Goroutines 以死锁告终

我有一个压力测试问题,想通过Go中的简单同步来解决。到目前为止,我已经尝试查找关于我在Go中同步的特定用例的文档,但没有找到合适的文档。更具体一点:我必须完成一项任务,我必须在主例程中启动大量线程(在此示例中仅使用两个线程进行说明)。所有被启动的worker都应该以无序的方式自己准备一些初始化Action。直到它们到达一个小的命令序列,我希望所有的goroutines一次执行它们,这就是为什么我想要让goroutines相互同步。对我的任务来说非常重要的是,通过实例化所有其他goroutine的主例程的延迟不会影响工作人员执行的真正并行性(在注释中的标签#maximumparallel

java - 从一个 ORM 迁移到另一个

这是我的问题。我现在正在使用Play2Framework,它为我提供了Ebean作为我的默认ORM产品。我对Java比较了解,决定用Java写一个网站,但我也想学习Go,最终把我网站的后端代码改成Go(Go的框架Revel)。我知道我的数据仍会存在,但我将不得不使用不同的ORM产品来重写所有模型。即使我保持完全相同的数据库结构,这会导致问题吗? 最佳答案 这取决于您对“问题”的定义。ORM框架提供了将数据库信息(关系数据)映射到OOP对象的工具。ORM框架之间存在差异,例如它们支持的DBMS、将表/列名映射到类/字段时的默认命名规则

multithreading - App Engine Channel API 的线程安全/原子性

当我尝试使用GoogleAppEngine的ChannelAPI从两个或多个goroutines和/或任务队列发送消息时会发生什么?例如gochannel.Send(context,clientID,"Hello")gochannel.Send(context,clientID,"World")我知道在GAEGo中,所有goroutines都被多路复用到一个线程上。然而,这仍然允许在I/O期间进行抢占,并且channel发送可能符合I/O的条件。GAE开发服务器似乎序列化了所有请求,所以我没有看到任何channel发送重叠。生产服务器似乎允许一些请求并发,但channel发送看起来是原

java - 防止服务器在客户端(golang)服务器(Java)应用程序中终止

我有一个简单的Java回显服务器:intportNumber=4444;try(ServerSocketserverSocket=newServerSocket(Integer.parseInt(args[0]));SocketclientSocket=serverSocket.accept();PrintWriterout=newPrintWriter(clientSocket.getOutputStream(),true);BufferedReaderin=newBufferedReader(newInputStreamReader(clientSocket.getInputStr

java - 谷歌云端点生成 Java api HTTP 400 错误

嘿,我正在尝试使用此文档开发一个休息APIgo-endpoints我可以在本地和应用引擎上测试我的应用。但我无法创建Java客户端以便在Android设备上使用它,出于某种原因,我得到了一个HTTP400NoJSONobjectcouldbedecoded在这个命令上GO_SDK/endpointscfg.pygen_client_libjavaMY_FILE_NAME这是完整的堆栈跟踪mik@mik-Aspire-S3:~/go-programs/src/cloudEndPoints/app$$HOME/go_appengine/endpointscfg.pygen_client_l